package com.yy.utils;

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * 描述 线程池工具类
 * 作者 yy
 */
public class AppThreadPoolUtils {
    /**
     * 导ES的线程池
     * 思考   corePoolSize  maximunPoolSize   blockQueue的大小如何设计
     * IO  密集型的任务怎么设置
     * CPU 密集型的任务怎么设置
     */
    public static ThreadPoolExecutor esPoolExecutor=new ThreadPoolExecutor(
            10, //核心线程数
            10,//最大线程数
            60,//线程回收时间
            TimeUnit.SECONDS,//回收时间长的单位
            new LinkedBlockingQueue<>(10)//任务队列
    );
}
